package com.cn.yang.dao.impl;

import com.cn.yang.dao.MessageDao;
import com.cn.yang.model.message.MessageModel;
import com.cn.yang.model.news.NewsModel;
import com.cn.yang.util.GetSqlSession;
import com.cn.yang.util.JDBC;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class MessageDaoImpl implements MessageDao {
    JDBC jdbc = new JDBC();
    //添加Message的信息 留言====
    @Override
    public int addMessage(MessageModel model) {
        return GetSqlSession.getSqlSession().insert("com.cn.yang.dao.MessageDao.addMessage",model);
    }
//删除一条数据
    @Override
    public int deleteById(Integer id) {
        return GetSqlSession.getSqlSession().delete("com.cn.yang.dao.MessageDao.deleteById",id);
    }
//总计多少数据
    @Override
    public int countNews() {
        return GetSqlSession.getSqlSession().selectOne("com.cn.yang.dao.MessageDao.countNews");
    }
//查询数据
    @Override
    public List<MessageModel> findMessage(MessageModel model) {
        return GetSqlSession.getSqlSession().selectList("com.cn.yang.dao.MessageDao.findMessage",model);
    }
//更新数据
    @Override
    public int updateMessage(MessageModel model) {
        return GetSqlSession.getSqlSession().update("com.cn.yang.dao.MessageDao.updateMessage",model);
    }
//查询一条数据
    @Override
    public MessageModel selectById(Integer id) {
        return GetSqlSession.getSqlSession().selectOne("com.cn.yang.dao.MessageDao.selectById",id);
    }
}
